package cn.com.bluemoon.daps.common.toolkit.valueobject;

import java.util.List;
import java.util.concurrent.Callable;

/**
 * 收集一个分片的任务
 *
 * @author Jarod Kong
 * @date 2021-03-27 08:53
 **/
public interface MyQueryCallable<T> extends MyQueryCount {
    /**
     * 定义一个任务的查询逻辑
     *
     * @param offset 查询db的offset
     * @param limit 查询db的总数
     * @return 一个任务
     */
    Callable<List<T>> callTask(int offset, int limit);
}